package package.test;

import io.netty.handler.codec.http.DefaultHttpHeaders;
import io.netty.handler.codec.http.HttpHeaders;
import org.asynchttpclient.*;
import org.asynchttpclient.proxy.ProxyType;

import java.io.IOException;
import java.util.concurrent.ExecutionException;

import static org.asynchttpclient.Dsl.*;
import static org.asynchttpclient.Dsl.basicAuthRealm;

public class Test {
    public static void main(String[] args) throws ExecutionException, InterruptedException, IOException {
        AsyncHttpClient client = asyncHttpClient();
        Request request = new RequestBuilder()
                .setMethod("GET")
                .setUrl("https://www.google.com")
                .setProxyServer(
                        proxyServer("proxy.host", 8080)
                                .setProxyType(ProxyType.SOCKS_V5)
                                .setRealm(basicAuthRealm("user", "password").setUsePreemptiveAuth(true))
                                .setCustomHeaders(req -> {
                                        HttpHeaders headers = new DefaultHttpHeaders().clear();
                                        headers.add("Custom-Header", "custom value");
                                        return headers;
                                })
                )
                .build();
        ListenableFuture<Response> response = client.executeRequest(request);
        int status = response.get().getStatusCode();
        System.out.println(status);
        client.close();
    }
}